package se.kernel;

import java.io.BufferedReader;
import java.io.IOException;

public class ThreadRecibirMensajes extends Thread
{
    private Conversacion conversacion;

    private BufferedReader sockIn;

    public ThreadRecibirMensajes( Conversacion conversacion, BufferedReader sockIn )
    {
        this.sockIn = sockIn;
        this.conversacion = conversacion;
    }

    @Override
    public void run( )
    {
        super.run( );
        try
        {
            recibirMensajes( );
        }
        catch( IOException e )
        {
            e.printStackTrace( );
        }
    }

    public void recibirMensajes( ) throws IOException
    {
        boolean activo = true;
        while( activo )
        {
            String[] mensaje = sockIn.readLine( ).split( ":" );
            if( mensaje[ 0 ].equals( Conversacion.MENSAJE ) )
                conversacion.recibirMensaje( mensaje[ 1 ] );
            else if( mensaje[ 0 ].equals( Conversacion.ARCHIVO ) )
                conversacion.recibirArchivo( mensaje[ 1 ], Integer.valueOf( mensaje[ 2 ] ) );
        }
    }
}
